//package com.safone.thirdattendanceservices.activemq;
//
//import org.apache.activemq.ActiveMQConnectionFactory;
//import javax.jms.*;
//import java.io.IOException;
///**
// * @author xy
// * @date 2020/12/23 16:21
// */
//public class JmsConsumerTopic {
//    public static void main(String[] args) throws Exception{
////        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://39.105.39.212:61616");
////        Connection connection = connectionFactory.createConnection("admin", "0a4bd0d766f44246");
//        //连接工厂
//        ConnectionFactory connectionFactory;
//        //连接
//        Connection connection = null;
//        //会话 接受或者发送消息的线程
//        Session session;
//        //消息的目的地
//        Destination destination;
//        //消息生产者
//        MessageProducer messageProducer;
//        //实例化连接工厂
//        connectionFactory = new ActiveMQConnectionFactory("admin", "0a4bd0d766f44246", "tcp://39.105.39.212:59004");
//
//        try {
//            //通过连接工厂获取连接
//            connection = connectionFactory.createConnection();
//            //启动连接
//            connection.start();
//            //创建session
//            session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
//            //创建一个名称为HelloWorld的消息队列
//            destination = session.createQueue("HelloWorld");
//            //创建消息生产者
//            messageProducer = session.createProducer(destination);
//            //发送消息
//            sendMessage(session, messageProducer);
//
//            session.commit();
//
//        } catch (Exception e) {
//            e.printStackTrace();
//        }finally{
//            if(connection != null){
//                try {
//                    connection.close();
//                } catch (JMSException e) {
//                    e.printStackTrace();
//                }
//            }
//        }
//
//
//    }}
